package com.springcloud.test;

import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;

/**
 * @Desc TODO
 * ----------------
 * @CLASS_NAME: ExampleReceiver
 * ----------------
 * @Author jovi
 * ----------------
 * @Date 2020-04-02 10:47
 */
@Slf4j
@EnableBinding(ExampleBinder.class)
public class ExampleReceiver {

    @StreamListener(ExampleBinder.NAME)
    public void receive(String payload) {
        log.info("Received: " + payload);
    }
}
